#include"Blockqueue.hpp"

void* consumer(void* args)
{
    Blockqueue *bp=static_cast<Blockqueue*>(args);
    
}
void* produce(void* args)
{
    Blockqueue *bp=static_cast<Blockqueue*>(args);
}
int main()
{
    //首先构建单生产单消费模型
    Blockqueue* n1=new Blockqueue();
    pthread_t c,p;
    pthread_create(&c,nullptr,consumer,n1);
    pthread_create(&p,nullptr,produce,n1);



    pthread_join(c,nullptr);
    pthread_join(p,nullptr);
    return 0;
}